package io.kimmking.mq.alphamq;

public interface IPublisher<T> {
    
    void publish(String topic, IMessage<T> message) throws MQException;
    
}
